//import java.util.concurrent.ArrayBlockingQueue;
//import java.util.concurrent.BlockingQueue;
//
///**
// * Created with IntelliJ IDEA.
// * Description:
// * User:
// * Date: 2025-10-14
// * Time: 11:11
// */
//class MyThreadPool1{
//    private BlockingQueue<Runnable> queue = null;
//
//    public MyThreadPoo1l(int n){
//        queue = new ArrayBlockingQueue<>(1000);
//
//        for(int i = 0; i < n; i++){
//            Thread t = new Thread(() -> {
//                try{
//                    while(true){
//                        Runnable task = queue.take();
//                        task.run();
//                    }
//
//                }catch (InterruptedException e){
//                    e.printStackTrace();
//                }
//            });
//            t.start();
//        }
//    }
//
//    public void submit(Runnable task) throws InterruptedException{
//        queue.put(task);
//    }
//}
//
//public class demo3 {
//    public static void main(String[] args) throws InterruptedException {
//        MyThreadPool1 pool = new MyThreadPool1(10);
//
//        for (int i = 0; i < 100; i++) {
//            int id = i;
//            pool.submit(() -> {
//                System.out.println(Thread.currentThread().getName() + " id:" + id);
//            });
//        }
//    }
//}
